

'use strict';
const BaseController = require('../base/base');

class TtbPushController extends BaseController {

    /**
     * 获取推送列表
     */
    async list(){
        const ctx = this.ctx;
        const query =ctx.query;
        var data = await ctx.service.push.ttbPush.list(query);
        data =ctx.convertToAntTableData(data);
        ctx.outSuccess(null, data);
    }

    /**
     * 处理推送
     */
    async pushdeal(){
        const ctx = this.ctx;
        let params ={};
        params = Object.assign(params,ctx.request.body);
        let res = await ctx.service.push.ttbPush.pushdeal(params);
        if(res.success === false){
            return ctx.outError(res.msg || '推送失败',null,res.response_code_enum || ctx.app.enums.response_code_enum.server_error);
        }
        ctx.outSuccess('推送成功',res.data || {});
    }

    /**
     * 根据推送id执行一次推送
     */
    async push(){
        const ctx = this.ctx;
        let params ={
            id:ctx.params.id || 0
        };
        let res = await ctx.service.push.ttbPush.push(params);
        if(res.success === false){
            return ctx.outError(res.msg || '推送失败',null,res.response_code_enum || ctx.app.enums.response_code_enum.server_error);
        }
        ctx.outSuccess('推送成功',res.data || {});
    }

    /**
     * 查询推送结果详情
     */
    async pushDetail(){
        const ctx = this.ctx;
        let params ={};
        params = Object.assign(params,ctx.query);
        let res = await ctx.service.push.ttbPush.pushDetail(params);
        if(res.success === false){
            return ctx.outError(res.msg || '获取失败',res.data || {},res.response_code_enum || ctx.app.enums.response_code_enum.server_error);
        }
        console.log('pushDetail=>> ',res);
        ctx.outSuccess('',res.data || {});
    }

}

module.exports = TtbPushController;